const fs = require('fs')
const path = require('path')
const ProtoBuf = require('protobufjs')
const WebSocket = require('ws')
const WebSocketServer = WebSocket.Server
const wss = new WebSocketServer({ port: 9000 })
/* 创建TCP客户端 */
const write = (data) => {
    fs.writeFile('./test.txt', data, { 'flag': 'a' }, function (err) {
        if (err) {
            throw err;
        }
        console.log('write');
    });
}
const read = () => {
    fs.readFile('./test.txt', 'utf-8', function (err, data) {
        if (err) {
            throw err;
        }
        console.log(data);
    });
}
const UAV = {
    UAV_Y: true,
    UAVposit: [22.61, 114.13, 100]
}
wss.on('connection', (ws, req) => {
    console.log('connection')
    // 接收客户端信息并把信息返回发送
    // ws.on('message', (message) => {

    var int = setInterval(function f() {
        if (UAV.UAVposit[0] > 22.621112) UAV.UAV_Y = true
        if (UAV.UAVposit[0] < 22.600000) UAV.UAV_Y = false
        if (UAV.UAV_Y) {
            UAV.UAVposit[0] -= 0.00005
        } else {
            UAV.UAVposit[0] += 0.00005
        }
        const obj = {
            "id": "GX001",
            "img": "./site/1.png",
            "status": "在线",
            "videoUrl": "rtmp://120.76.41.198:8881/hls/1517080009",
            "pos": UAV.UAVposit,
            "packet": 1,
            "building": -1,
            "time": "2019-04-24 11:03:00"
        }
        const message = JSON.stringify(obj)
        ws.send(message, (err) => { // send 方法的第二个参数是一个错误回调函数
            if (err) {
                console.log(`[SERVER] error: ${err}`);
            }
        })
    }, 1000)
    // })
})
// ProtoBuf.load("./automsg.proto", function (err, root) {
//     if (err)
//         throw err;
//     var AwesomeMessage = root.lookupType("basicTypes.vec3f");

//     var payload = { x: 1, y: 123, z: 3 };

//     var message = AwesomeMessage.create(payload);

//     var buffer = AwesomeMessage.encode(message).finish();
//     // const buf = ProtoBuf.util.newBuffer(buffer)
//     // console.log(buf)
//     // var buffer1 = AwesomeMessage.decode(buffer)
//     var int = setInterval(function f() {
//         wss.clients.forEach(function each(client) {
//             console.log(buffer)
//             // const data = {
//             //     source: 'data',
//             //     data: buffer
//             // }
//             client.send(buffer)
//             // client.send(<Buffer  >)
//         })
//     }, 2000)
// })

